package com.my.stock.core;

import org.zeromq.ZMQ;

public class MockData {

	public static void main(String[] args) throws InterruptedException {

		String sg = "sp2301,6736,6736,6736,6736,6736,20220817#13:40:54#800,13:40:54";
		ZMQ.Context context = ZMQ.context(1);
		ZMQ.Socket s = context.socket(ZMQ.PUB);
		s.bind("tcp://127.0.0.1:5556");
		
		while (true) {
			
			Thread.sleep(1000*10);
			s.send(sg);
			 sg = "sp2301,6736,6746,6716,6736,6736,20220817#13:40:54#800,13:40:54";
			 s.send(sg);
		}
	}
}
